7c073c11ac4716879686badd632e2709e5d190c1,tests/test_apps/txnid-selfcheck2/src/txnIdSelfCheck/ClientThread.java,ClientThread,runOne,#,120
Before Change
m_txnsRun.incrementAndGet();
if (results.length != expectedTables) {
log.error(String.format(
"Client cid %d procedure %s returned %d results instead of %d",
m_cid, procName, results.length, expectedTables));
log.error(((ClientResponseImpl) response).toJSONString());
Benchmark.printJStack();
System.exit(-1);
}
After Change
ClientResponse response;
try {
response = m_client.callProcedure(procName,
m_cid,
m_nextRid,
payload,
shouldRollback);
} catch (Exception e) {
if (shouldRollback == 0) {
log.warn("ClientThread threw after " + m_txnsRun.get() +
" calls while calling procedure: " + procName +
" with args: cid: " + m_cid + ", nextRid: " + m_nextRid +
", payload: " + payload +
", shouldRollback: " + shouldRollback);
}
throw e;
}
// fake a proc call exception if we think one should be thrown
if (response.getStatus() != ClientResponse.SUCCESS) {
throw new UserProcCallException(response);
}
VoltTable[] results = response.getResults();
m_txnsRun.incrementAndGet();
if (results.length != expectedTables) {
hardStop(String.format(
"Client cid %d procedure %s returned %d results instead of %d",
m_cid, procName, results.length, expectedTables), response);
}
VoltTable data = results[3];
try {